package org.nacos.consumer.config;

import java.util.function.Consumer;

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

import lombok.extern.slf4j.Slf4j;

@Slf4j
@Configuration
public class ConsumerConfig {

	@Bean("order")
    Consumer<Object> order() {
        log.info("初始化订阅");
        return msg -> {
            log.info("通过 stream 消费到消息 => {}", msg);
        };
    }

}
